/*
package com.back.controller.rocketmqDemo;

import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.spring.core.RocketMQTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.Message;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
@RequestMapping("/rocket")
public class P {
    @Autowired
    private RocketMQTemplate rocketMQTemplate;

    */
/**
     * 发送同步消息
     * @param messageBody 消息内容
     *//*

    @GetMapping("sendMessage")
    public void sendSyncMessage(String messageBody) {
        // 2. 发送消息
        // destination 格式通常为 "topic:tag"（如 "TopicTest:TagA"），也可以只有 topic（如 "TopicTest"）
        // payload 是消息体，可以是对象（Spring会序列化）
        // 同步发送会等待Broker响应，返回SendResult
        SendResult sendResult = rocketMQTemplate.syncSend("TopicTest:TagA", messageBody);
        System.out.println("同步消息发送成功: " + sendResult);
    }

    */
/**
     * 发送带Key的消息
     * @param orderId 业务键
     * @param messageBody 消息内容
     *//*

    @GetMapping("sendKye")
    public void sendMessageWithKey(String orderId, String messageBody) {
        // 3. 构建 Spring Message，可以设置 headers（如KEYS）
        // 设置KEYS便于后续通过业务标识查询消息
        Message<String> message = MessageBuilder.withPayload(messageBody)
                .setHeader("KEYS", orderId) // 或者使用 RocketMQHeaders.KEYS
                .build();

        SendResult sendResult = rocketMQTemplate.syncSend("TopicTest:TagA", message);
        System.out.println("带Key消息发送成功: " + sendResult);
    }
}
*/
